package com.imooc.concurrency.example.mq;


import com.imooc.concurrency.example.mq.kafka.KafkaSender;
import com.imooc.concurrency.example.mq.rabbitmq.RabbitMQClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

@RestController
@RequestMapping("/mq")
public class MQController {

//    @Resource
//    private RabbitMQClient rabbitMQClient;

//    @Resource
//    private KafkaSender kafkaSender;

    @RequestMapping("/send")
    public String send(String message){
//        rabbitMQClient.send(message);
//        kafkaSender.send(message);
        return "success";
    }
}
